package org.example.BIO_Turn;

import org.example.BIO_03.SocketHandler;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Arrays;

/**
 * 群发：拿集合存socket，接收到消息进行一个群发操作
 */
public class Server {
    // 上线的集合列表
    public static ArrayList<Socket> socketArrayList = new ArrayList<>();

    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(9999);
        System.out.println("服务端启动，端口：9999");
        while (true) {
            Socket accept = ss.accept();
            // 存入集合
            socketArrayList.add(accept);
            new Thread(new Task(accept)).start();
        }
    }
}
